const mysql = require('mysql')
const pool = mysql.createPool({
    host: '192.168.0.253',
    user: 'root',
    password: 'yiqifu@123',
    database: 'hcsy',
    port: 3306
})
var loggerInfo = require('./winston-date').logger;// 自定义打印 包含日志文件分割功能
var loggerReeor = require('./winston-date').loggerError;
// 接收一个sql语句 以及所需的values
// 这里接收第二参数values的原因是可以使用mysql的占位符 '?'
// 比如 query(`select * from my_database where id = ?`, [1])

let query = function (sql, values) {
    // 返回一个 Promise
    return new Promise((resolve, reject) => {
        pool.getConnection(function (err, connection) {
            if (err) {
                reject(err);
                loggerError.error("pool.getConnection>",err);
            } else {
                connection.query(sql, values, (err, rows) => {
                    if (err) {
                        reject(err);
                        loggerError.error("pool.getConnection>connection.query>",err);
                    } else {
                        resolve(rows);
                    }
                    // 结束会话
                    connection.release();
                })
            }
        })
    })
}
module.exports = query;
